Code Coverage
 
Classes and Traits
Functions and Methods
Lines
Total
0.00% covered (danger)
0.00%
0 / 1
33.33% covered (danger)
33.33%
3 / 9
 CRAP
88.89% covered (warning)
88.89%
48 / 54
ProjectRepository
0.00% covered (danger)
0.00%
0 / 1
33.33% covered (danger)
33.33%
3 / 9
 16.35
88.89% covered (warning)
88.89%
48 / 54
 getIdentifierProperties
0.00% covered (danger)
0.00%
0 / 1
 2.00
0.00% covered (danger)
0.00%
0 / 1
 findOneByIdentifier
100.00% covered (success)
100.00%
1 / 1
 1
100.00% covered (success)
100.00%
1 / 1
 findBySearch
0.00% covered (danger)
0.00%
0 / 1
 4
95.45% covered (success)
95.45%
21 / 22
 findAll
0.00% covered (danger)
0.00%
0 / 1
 2.06
75.00% covered (warning)
75.00%
3 / 4
 findByIds
0.00% covered (danger)
0.00%
0 / 1
 2.02
83.33% covered (warning)
83.33%
5 / 6
 findByLocale
0.00% covered (danger)
0.00%
0 / 1
 2.03
80.00% covered (warning)
80.00%
4 / 5
 findByChannel
0.00% covered (danger)
0.00%
0 / 1
 2.03
80.00% covered (warning)
80.00%
4 / 5
 setCursorFactory
100.00% covered (success)
100.00%
1 / 1
 1
100.00% covered (success)
100.00%
2 / 2
 configureSearchOptions
100.00% covered (success)
100.00%
1 / 1
 1
100.00% covered (success)
100.00%
8 / 8
<?php
/*
 * This file is part of the Akeneo PIM Enterprise Edition.
 *
 * (c) 2016 Akeneo SAS (http://www.akeneo.com)
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */
namespace Akeneo\Pim\WorkOrganization\TeamworkAssistant\Bundle\Doctrine\ORM\Repository;
use Akeneo\Channel\Component\Model\ChannelInterface;
use Akeneo\Channel\Component\Model\LocaleInterface;
use Akeneo\Pim\WorkOrganization\TeamworkAssistant\Component\Model\ProjectInterface;
use Akeneo\Pim\WorkOrganization\TeamworkAssistant\Component\Repository\ProjectRepositoryInterface;
use Akeneo\Tool\Component\StorageUtils\Cursor\CursorFactoryInterface;
use Akeneo\Tool\Component\StorageUtils\Cursor\CursorInterface;
use Akeneo\UserManagement\Component\Model\GroupInterface;
use Akeneo\UserManagement\Component\Model\UserInterface;
use Doctrine\ORM\EntityRepository;
use Symfony\Component\OptionsResolver\OptionsResolver;
/**
 * @author Olivier Soulet <olivier.soulet@akeneo.com>
 */
class ProjectRepository extends EntityRepository implements ProjectRepositoryInterface
{
    /** @var CursorFactoryInterface */
    protected $cursorFactory;
    /**
     * {@inheritdoc}
     */
    public function getIdentifierProperties()
    {
        return ['code'];
    }
    /**
     * {@inheritdoc}
     *
     * @return ProjectInterface
     */
    public function findOneByIdentifier($identifier)
    {
        return $this->findOneBy(['code' => $identifier]);
    }
    /**
     * Allow to find projects by search on label, on projects that a user can access and paginate results.
     *
     * {@inheritdoc}
     *
     * @return ProjectInterface[]
     */
    public function findBySearch($search = null, array $options = null)
    {
        $searchResolver = $this->configureSearchOptions();
        $options = $searchResolver->resolve($options);
        $qb = $this->createQueryBuilder('project');
        $qb->distinct(true);
        $qb->leftJoin('project.userGroups', 'u_groups');
        $qb->join('project.owner', 'owner');
        $userGroups = $options['user']->getGroups();
        if (!$userGroups->isEmpty()) {
            $userGroupsId = array_map(
                function (GroupInterface $userGroup) {
                    return $userGroup->getId();
                },
                $userGroups->toArray()
            );
            $qb->orWhere($qb->expr()->in('u_groups.id', ':groups'));
            $qb->setParameter(':groups', $userGroupsId);
        }
        $qb->orWhere($qb->expr()->eq('owner.username', ':username'));
        $qb->setParameter('username', $options['user']->getUsername());
        if (null !== $search && '' !== $search) {
            $qb->andWhere('project.label LIKE :search')->setParameter('search', sprintf('%%%s%%', $search));
        }
        $qb->setMaxResults($options['limit']);
        $qb->setFirstResult($options['limit'] * ($options['page'] - 1));
        $qb->orderBy('project.dueDate');
        return $qb->getQuery()->execute();
    }
    /**
     * Returns a cursor with all products
     *
     * @throws \RuntimeException If cursor has not been set
     *
     * @return CursorInterface
     */
    public function findAll()
    {
        if (null === $this->cursorFactory) {
            throw new \LogicException('The cursor factory is not initialized');
        }
        $qb = $this->createQueryBuilder('project');
        return $this->cursorFactory->createCursor($qb);
    }
    /**
     * {@inheritdoc}
     */
    public function findByIds(array $projectIds)
    {
        if (empty($projectIds)) {
            throw new \InvalidArgumentException('Array must contain at least one project id');
        }
        $qb = $this->createQueryBuilder('project');
        $qb->where($qb->expr()->in('project.id', ':project_ids'));
        $qb->setParameter(':project_ids', $projectIds);
        return $qb->getQuery()->getResult();
    }
    /**
     * {@inheritdoc}
     */
    public function findByLocale(LocaleInterface $locale)
    {
        if (null === $this->cursorFactory) {
            throw new \LogicException('The cursor factory is not initialized');
        }
        $qb = $this->createQueryBuilder('project');
        $qb->where($qb->expr()->eq('project.locale', $locale->getId()));
        return $this->cursorFactory->createCursor($qb);
    }
    /**
     * {@inheritdoc}
     */
    public function findByChannel(ChannelInterface $channel)
    {
        if (null === $this->cursorFactory) {
            throw new \LogicException('The cursor factory is not initialized');
        }
        $qb = $this->createQueryBuilder('project');
        $qb->where($qb->expr()->eq('project.channel', $channel->getId()));
        return $this->cursorFactory->createCursor($qb);
    }
    /**
     * @param CursorFactoryInterface $cursorFactory
     */
    public function setCursorFactory(CursorFactoryInterface $cursorFactory)
    {
        $this->cursorFactory = $cursorFactory;
    }
    /**
     * Initialize, configure and returns an options resolver for findBySearch query.
     *
     * @return OptionsResolver
     */
    protected function configureSearchOptions()
    {
        $searchResolver = new OptionsResolver();
        $searchResolver->setRequired(['user']);
        $searchResolver->setDefault('limit', 20);
        $searchResolver->setDefault('page', 1);
        $searchResolver->setAllowedTypes('limit', 'numeric');
        $searchResolver->setAllowedTypes('page', 'numeric');
        $searchResolver->setAllowedTypes('user', UserInterface::class);
        return $searchResolver;
    }
}